//package com.surfilter.mq.rocketmq;
//
//import com.surfilter.funds.task.entity.TaskManage;
//import com.surfilter.mq.util.ByteUtils;
//
//import java.io.IOException;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//
///**
// * @author JinYongjie
// * @ClassName CaheMessages
// * @Description 将任务缓存到Map,和复制、删除map对象的方法。
// *
// */
//public class CaheMessages {
//
//	private static Map<Integer, TaskManage> taskMap = new HashMap<Integer, TaskManage>();
//
//	public static Map<Integer, TaskManage> getTaskMap() {
//		return taskMap;
//	}
//
//	public static void setTaskMap(Map<Integer, TaskManage> taskMap) {
//		CaheMessages.taskMap = taskMap;
//	}
//
//	/**
////	 * @Description 反序列化数据，将任务对象放入Map缓存
//	 * @param messages 序列化后的任务对象
//	 */
//	public static void caseAdd(List<byte[]> messages) {
//		if (messages != null && !messages.isEmpty()) {
//			synchronized (taskMap) {
//				for (byte[] message : messages) {
//					try {
//						TaskManage taskManage = (TaskManage) ByteUtils
//								.deserialize(message);
//						taskMap.put(taskManage.getId(), taskManage);
//					} catch (IOException e) {
//						e.printStackTrace();
//					}
//				}
//			}
//		}
//	}
//
//	/**
//	 * @Description 复制对象
//	 * @return cloneData,TaskManage任务对象集合
//	 */
//	public static Map<Integer, TaskManage> cloneData() {
//		Map<Integer, TaskManage> mapCopy = new HashMap<Integer, TaskManage>();
//		synchronized (taskMap) {
//			for( Integer key: taskMap.keySet()){
//				mapCopy.put(key, taskMap.get(key));
//			}
//		}
//		return mapCopy;
//	}
//	/**
//	 * @Description 根据key值删除Map中的元素
//	 * @param key
//	 */
//	public static void deleteData(Integer key) {
//		synchronized (taskMap) {
//			taskMap.remove(key);
//		}
//	}
//
//}
